#pragma once

#include "common/Pipeline.h"

namespace nexus {

class Aggregator {
 public:
  Aggregator(Pipeline& pipeline);
  void run();

 private:
  void process(AtomicOverwrite& ao, AtomicOverwrite& out);

  Pipeline& pipeline_;
};

}  // namespace nexus